package ex.datastream.functions.timestampAssigner;

import ex.datatypes.TaxiRide;
import org.apache.flink.api.common.eventtime.SerializableTimestampAssigner;


public  class MyAssigner implements SerializableTimestampAssigner<TaxiRide> {
    @Override
    public long extractTimestamp(TaxiRide taxiRide, long l) {
        return taxiRide.getEventTimeMillis();
    }
}

